/*
    fs.createReadStream(path[, options])
        - path 是文件路径
        - options 可选参数
            - start  读取的起始位置
            - end    读取的结束位置
            - highWaterMark 每次读取的字节数量（默认值是：64 * 1024）
*/

// 导入文件系统模块
let fs = require('fs');
const { wrap } = require('module');

//创建流式文件读取对象
let cr = fs.createReadStream('gxb.jpg')
//创建流式文件写入对象
let cw = fs.createWriteStream('gxb2.jpg')
cr.once('open',function(){
    console.log('读取流开启了~');
})
cr.on('close',function(){
    console.log('读取流关闭了~');
    //当前读取流关闭的时候，关闭写入流
    cw.end()
})
cw.once('open',function(){
    console.log('写入流开启了~');
})
cw.once('close',function(){
    console.log('写入流关闭了~');
})

//通过监听data事件,来返回每次读取到的数据
cr.on('data',function(str){
   cw.write(str)
})

